package jp.co.dailyReport.project.sql;

import java.sql.Connection;
import java.sql.SQLException;
import java.sql.PreparedStatement;
import org.apache.log4j.Logger;
import jp.co.dailyReport.Executer;

/**
 * プロジェクト参加社員情報を削除するクラスです。
 */
public class PjStaffDeleteExecuter implements Executer {

	private static Logger log = Logger.getLogger(PjStaffDeleteExecuter.class);
	private int projectId;
	private int staffId;

	public PjStaffDeleteExecuter(int projectId,int staffId) {
		this.projectId = projectId;
		this.staffId = staffId;
	}

	/**
	 * 社員ID・プロジェクトIDを基に、プロジェクト参加社員情報を削除します。
	 * 
	 * @param conn コネクションオブジェクト
	 * @return null
	 * @throws SQLException
	 */
	public Object[] execute(Connection conn) throws SQLException {

		PreparedStatement pstmt = null;
		String sql = "update pjStaff set delFlg=1 where staffId=? and projectId=?";
		log.debug("sql: " + sql);
		try {
			pstmt = conn.prepareStatement(sql);
			pstmt.setInt(1, staffId);
			pstmt.setInt(2, projectId);
			pstmt.execute();
		} finally {
			if(pstmt != null)
			 pstmt.close();
		}
		return null;
	}
}